package com.kafka.spring.mq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface MqMessage {
        String SEND_COFFEE = "sendCoffee";

    @Output(SEND_COFFEE)
    MessageChannel sendCoffeeMessage();

    @Input(SEND_COFFEE)
    SubscribableChannel sendCoffeeSubscribable();
}
